/*
 * Consumer.h
 *
 *  Created on: 29.10.2013
 *      Author: ulgish
 */

#ifndef CONSUMER_H_
#define CONSUMER_H_

#include "DThread.h"
#include <SyncWriter.h>
namespace DT {

class Consumer: public DT::DThread {
	int count;
	//arg - pointer to object of Store
	virtual void* run(void* arg);
public:
	Consumer(int count);

	virtual ~Consumer();
};

}

#endif /* CONSUMER_H_ */
